package com.SparkCore.RDD.Builder

import org.apache.spark.{SparkConf, SparkContext}

/**
 * 从文件中创建RDD
 */
object Spark03_RDD_Feil_Par1 {
  def main(args: Array[String]): Unit = {

    //准备环境
    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("RDD") //setMaster("Local[*]") 表示默认核数
    val sc = new SparkContext(sparkConf)

    //创建RDD

    // 共十四个字节  14 / 7 = 2

    /**
     * 以偏移量来处理
     * 12345678@@  => 0 1 2 3 4 5 6 7 8 9
     * 4@@         => 10 11 12
     * 0           => 13
     *
     * [0,7]  1 2 3 4 5 6 7
     * [7,14]  4 0
     */
    val rdd = sc.textFile("datas/word.txt", 2)
    rdd.saveAsTextFile("output1")

    //关闭环境
    sc.stop()
  }
}
